#!/usr/bin/env.python
# _*_ coding:utf-8 _*_
# # # # # # # # # # # # # # # # # # # #
#  题目:      celery客户端             #
#  姓名:         李吉辉                #
#  时间:    2018年12月20日09:52:03     #
# # # # # # # # # # # # # # # # # # # #

from celery import Celery
import os

# ***** 如果当前没有加载settings文件,就手动指定加载路径
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 1.创建celery应用对象
celery_app = Celery("meiduo") # 传递的meiduo没有实际意义只是给celery应用对象起了一个别名

# 2.加载celery配置信息              配置路径 下自动找 broker_url
celery_app.config_from_object("celery_tasks.config")

# 3.自动注册异步任务(将需要的任务注册到监视者中)
#  对象      自动发现           路径下自动找 tasks文件
celery_app.autodiscover_tasks(["celery_tasks.sms", "celery_tasks.email", "celery_tasks.html"])